package com.ibest.base.entity;

import com.alibaba.fastjson.JSONObject;
import lombok.Getter;
import lombok.Setter;

import java.io.Serializable;
import java.util.List;

@Setter
@Getter
public class CanalBinlogBean implements Serializable {

    /**操作的数据*/
    private List<JSONObject> data;
    /**监听数据库名称*/
    private String database;

    private long es;
    //递增，从1开始
    private int id;
    /**是否是DDL语句*/
    private boolean isDdl;

    //表结构的字段类型
    private JSONObject mysqlType;
    /**UPDATE语句，旧数据*/
    private String old;
    /**主键名称，支持联合主键*/
    private List<String> pkNames;
    //sql语句
    private String sql;

    private JSONObject sqlType;
    //表名
    /**数据来源表名*/
    private String table;

    private long ts;
    /**(新增)INSERT、(更新)UPDATE、(删除)DELETE等等*/
    private String type;
}